package cn.me.alphamq.common.entity.req;

import cn.me.alphamq.common.entity.BaseMsg;

/**
 * 消费消息的请求对象
 *
 * @author f
 */
public class ConsumeMsgReq extends BaseMsg {

    /**
     * 消费的主题
     */
    private String topic;

    /**
     * 消费者组的名称
     */
    private String consumerGroup;

    /**
     * 消费队列的 id
     */
    private Integer queueId;

    /**
     * 消费者的 ip 地址
     */
    private String consumerIp;

    /**
     * 消费者的 端口号
     */
    private Integer consumerPort;

    /**
     * 消费者一次拉取的消息数量
     */
    private Integer batchMsgNum;

    public ConsumeMsgReq() {
    }

    public ConsumeMsgReq(String topic, String consumerGroup, Integer queueId, Integer batchMsgNum) {
        this.topic = topic;
        this.consumerGroup = consumerGroup;
        this.queueId = queueId;
        this.batchMsgNum = batchMsgNum;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getConsumerGroup() {
        return consumerGroup;
    }

    public void setConsumerGroup(String consumerGroup) {
        this.consumerGroup = consumerGroup;
    }

    public Integer getQueueId() {
        return queueId;
    }

    public void setQueueId(Integer queueId) {
        this.queueId = queueId;
    }

    public String getConsumerIp() {
        return consumerIp;
    }

    public void setConsumerIp(String consumerIp) {
        this.consumerIp = consumerIp;
    }

    public Integer getConsumerPort() {
        return consumerPort;
    }

    public void setConsumerPort(Integer consumerPort) {
        this.consumerPort = consumerPort;
    }

    public Integer getBatchMsgNum() {
        return batchMsgNum;
    }

    public void setBatchMsgNum(Integer batchMsgNum) {
        this.batchMsgNum = batchMsgNum;
    }
}
